package com.cetc.sdp.kmga.cs.util;

/**
 * @description:
 * @author： DengQiang
 * @date: 2018/3/9 17:02
 */
public class OpStreamJobConfImpl extends StreamJobConfImpl implements OpStreamJobConf {

    public OpStreamJobConfImpl(String configFile) {
        super(configFile);
    }

    @Override
    public String getUsrTableName() {
        return getStreamConf().get("hbase.user.index.table");
    }

    @Override
    public String getClientIpTableName() {
        return getStreamConf().get("hbase.clientip.index.table");
    }

    @Override
    public char getFillChar() {
        return getStreamConf().getOrDefault("fill.char", "|").charAt(0);
    }

    public static void main(String[] args) {
        new OpStreamJobConfImpl("audit-op-log-config.xml");
    }


}
